package org.mj.im.common;

import org.apache.rocketmq.client.producer.TransactionSendResult;
import org.mj.im.common.model.TopicMessage;

public interface MessageSenderService {
    boolean send(TopicMessage topicMessage);
    default TransactionSendResult sendMessageInTransaction(TopicMessage topicMessage, Object arg){
        return null;
    }
}
